package com.yan.common.mq.dirct;

        import org.springframework.amqp.rabbit.annotation.RabbitHandler;
        import org.springframework.amqp.rabbit.annotation.RabbitListener;
        import org.springframework.stereotype.Component;

/**
 * Created by yanl_ on 2018/4/18.
 */


@Component

public class DirctReceiverC {

    @RabbitListener(queues = "test3")    //监听器监听指定的Queue
    @RabbitHandler
    public void processC(String str) {
        System.out.println("Receive 3:===================================" + str);
    }

}
